package com.flume.demo1;

import org.apache.flume.Context;
import org.apache.flume.interceptor.Interceptor;

/**
 * @author shengtao
 * @Description:
 * @date 2019/01/11 18:21
 */
public class CounterInterceptorBuilder implements Interceptor.Builder {

    private Context ctx;

    @Override
    public Interceptor build() {
        return new CustomInterceptor(ctx);
    }

    @Override
    public void configure(Context context) {
        this.ctx = context;
    }
}
